package com.wy.blocking_queue;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingDeque;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingDeque;

/**
 * @author 美女
 * @date 2022/04/27 13:15
 **/
public class Main1 {
    public static void main(String[] args) throws InterruptedException {
      BlockingQueue<String> queue=new LinkedBlockingDeque<>();
////      普通队列
////        String poll= queue.poll();
////        System.out.println(poll);//能到达，结果：null
////      阻塞队列
//      String take=queue.take();//只要队列中取不到元素，就会一直阻塞在这
//        System.out.println("永远到达不了的语句");


        BlockingQueue<String> e=new ArrayBlockingQueue<>(3);//表示只能放三个元素
                                                                    //e.put()只能放三次，第四次就阻塞了
        e.put("1");
        e.put("2");
        e.put("3");
        e.put("4");
        queue.take();//只要队列中取不到元素，就会一直阻塞在这
        System.out.println("永远到达不了的语句");
    }
}
